package ihuotui.test;
import java.util.Date;
import java.util.concurrent.Callable; 
import java.util.concurrent.ExecutorService;   
import java.util.concurrent.Executors;   
import java.util.concurrent.Future; 
  
/*
 * Callable 和 Future接口  
 * Callable是类似于Runnable的接口,实现Callable接口的类和实现Runnable的类都是可被其它线程执行的任务。  
 * Callable和Runnable有几点不同:  
 * (1)Callable规定的方法是call(),而Runnable规定的方法是run().  
 * (2)Callable的任务执行后可返回值(任意类型),而Runnable的任务是不能返回值的。  
 * (3)call()方法可抛出异常,而run()方法是不能抛出异常的。  
 * (4)运行Callable任务可拿到一个Future对象,  
 * Future 表示异步计算的结果。它提供了检查计算是否完成的方法,以等待计算的完成,并检索计算的结果。  
 * 通过Future对象可了解任务执行情况,可取消任务的执行,还可获取任务执行的结果。  
 */  
public class CallableAndFuture {   
  
    /** *//**  
     * 自定义一个任务类,实现Callable接口  
     */  
    public static class MyCallableClass implements Callable{   
        // 标志位   
        private int flag = 0;   
        public MyCallableClass(int flag){   
            this.flag = flag;   
        }   
        public String call() throws Exception{ 
            if (this.flag == -1){
                Thread.sleep(1000);   
                return "time:"+new Date();   
            } 
            if (this.flag == 0){
                // 如果flag的值为0,则立即返回   
                return "flag = 0";   
            }    
            if (this.flag == 1){
                // 如果flag的值为1,做一个无限循环   
                try {   
                    while (true) {   
                        System.out.println("looping.");   
                        Thread.sleep(2000);   
                    }   
                } catch (InterruptedException e) {   
                    System.out.println("Interrupted");   
                }   
                return "false";   
            } else {   
                // falg不为0或者1,则抛出异常   
                throw new Exception("Bad flag value!");   
            }   
        }   
    }   
       
    public static void main(String[] args) {   
        // 定义3个Callable类型的任务   
        MyCallableClass task1 = new MyCallableClass(-1);   
        MyCallableClass task2 = new MyCallableClass(-1);   
        MyCallableClass task3 = new MyCallableClass(-1);   
           
        // 创建一个执行任务的服务   
        ExecutorService es = Executors.newFixedThreadPool(3);   
        try {   
            // 提交并执行任务,任务启动时返回了一个 Future对象,   
            // 如果想得到任务执行的结果或者是异常可对这个Future对象进行操作 
            System.out.println("new future "+new Date());
            Future future1 = es.submit(task1);  
            Future future2 = es.submit(task2); 
            Future future3 = es.submit(task3); 
            // 获得第一个任务的结果,如果调用get方法,当前线程会等待任务执行完毕后才往下执行   
             System.out.println("start get future "+new Date());
            System.out.println("task1: " + future1.get());  
            System.out.println("task1: " + future2.get()); 
            System.out.println("task1: " + future3.get()); 
            System.out.println("end get future "+new Date());
        } catch (Exception e){   
            System.out.println(e.toString());   
        }   
        // 停止任务执行服务   
        es.shutdownNow();   
    }   
}